#include "stepquerythread.h"

StepQueryThread::StepQueryThread()
{

}

void StepQueryThread::stopThread()
{
    this->queryStopped = true;
}

const QString StepQueryThread::getTime() const
{
    return QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss");
}

void StepQueryThread::setQuery(QString q)
{
    this->m_query = q;
}

void StepQueryThread::setRowCnt(int n)
{
    this->rowCnt = n;
}

StepQueryThread::~StepQueryThread()
{
    qDebug() << "thread deleted";
}

void StepQueryThread::run()
{
    queryList.clear();
    QSqlQuery query(db);
    queryStopped = false;

    while(!queryStopped){

        query.exec(m_query);
        query.next();

        for(int i = 0; i < rowCnt; ++i)
        {
            queryList.append(query.value(i).toString());
        }

        emit emitInfo(queryList);
        queryList.clear();

        msleep(1000);
    }
    quit();
}

//bool StepQueryThread::makeConnToDb()
//{
//    db.setHostName("localhost");
//    db.setPort(3306);
//    db.setUserName("root");
//    db.setPassword("");
//    db.setDatabaseName("test");
//    db.open();

//    if(!db.open()){
//        QMessageBox::critical(nullptr, "错误", "无法连接到数据库", QMessageBox::Ok | QMessageBox::Cancel);
//        return false;
//    }
//    else {
//        qDebug() << "thread made conn";
//    }
//    return true;
//}
